/*
 * @Descripttion: webSocket
 * @Define: main.js 中 import * as socketApi from './common/scripts/socket'; Vue.prototype.$socket = socketApi;
 * @Use: this.$scoket.createWebSocket(url);
 * @Author: yeming
 * @Date: 2018-06-09 10:17:28
 * 在线测试 http://www.websocket-test.com/
 */

var websock = null;
let rec; // 断线重连后，延迟5秒重新创建 WebSocket 连接; rec 用来存储延迟请求的代码
let isConnect = false; // 连接标识 避免重复连接
let timeoutObj = null; // 延时发送消息对象（启动心跳新建这个对象，收到消息后重置对象）
let checkMsg = "heartbeat"; // 心跳发送/返回的信息 服务器和客户端收到的信息内容如果如下 就识别为心跳信息 不要做业务处理

var globalCallback = function () {};

let createWebSocket = (url) => {
  try {
    var ws = url;
    initWebSocket(ws); // 初始化websocket连接
  } catch (e) {
    console.log("尝试创建连接失败");
    reConnect(); // 如果无法连接上 webSocket 那么重新连接！可能会因为服务器重新部署，或者短暂断网等导致无法创建连接
  }
};

// 初始化 websocket
function initWebSocket(url) {
  var ws = url;
  websock = new WebSocket(ws);
  websock.onopen = function () {
    websocketOpen();
    // heartCheck.start();
  }
  websock.onmessage = function (e) {
    websocketonmessage(e)
  }
  websock.onclose = function (e) {
    websocketclose(e)
  }
  websock.onerror = function () {
    // console.log('WebSocket连接发生错误');
    isConnect = false; // 连接断开修改标识
    reConnect(); // 连接错误 需要重连
  }
}

// 创建 websocket 连接
function websocketOpen(e) {
  console.log('webSocket 已打开，连接成功！')
}

// websocket 数据接收
function websocketonmessage(e) {
  // let O_o = JSON.parse(decodeUnicode(e.data));
  let O_o = JSON.parse(decodeURIComponent(e.data));
  if (!O_o) {
    heartCheck.reset();
  } else {
    if (O_o.msg === "open success") {
      // ...
    } else {
      globalCallback(O_o);
      // console.log(O_o);
    }
  }

  function decodeUnicode(str) {
    str = str.replace(/\\/g, "%");
    //转换中文
    str = unescape(str);
    //将其他受影响的转换回原来
    str = str.replace(/%/g, "\\");
    //对网址的链接进行处理
    str = str.replace(/\\/g, "");
    return str;
  }
}

// websocket 关闭
function websocketclose(e) {
  isConnect = false; // 断开后修改标识
  console.log(e);
  console.log('connection closed (' + e.code + ')');
}

// 定义重连函数
let reConnect = () => {
  console.log("尝试重新连接");
  if (isConnect) return; // 如果已经连上就不在重连了
  rec && clearTimeout(rec);
  rec = setTimeout(function () { // 延迟5秒重连  避免过多次过频繁请求重连
    createWebSocket();
  }, 5000);
};

// 设置关闭连接
let closeWebSocket = () => {
  webSocket.close();
};

// 心跳设置
var heartCheck = {
  timeout: 10000, // 每段时间发送一次心跳包 这里设置为20s
  start: function () {
    timeoutObj = setTimeout(function () {
      if (isConnect) websock.send(checkMsg);
    }, this.timeout);
  },
  reset: function () {
    clearTimeout(timeoutObj);
    timeoutObj = null;
    this.start();
  }
};

// 实际调用的方法
function sendSocket(agentData, callback) {
  globalCallback = callback;
  // console.log(globalCallback);
  if (websock.readyState === websock.OPEN) {
    // 若是 ws 开启状态
    websocketsend(agentData);
  } else if (websock.readyState === websock.CONNECTING) {
    // 若是 正在开启状态，则等待1s后重新调用
    setTimeout(function () {
      sendSocket(agentData, callback);
    }, 1000);
  } else {
    // 若未开启 ，则等待1s后重新调用
    setTimeout(function () {
      sendSocket(agentData, callback);
    }, 1000)
  }
}

function getSocket(callback) {
  globalCallback = callback
}

// 数据发送
function websocketsend(agentData) {
  websock.send(JSON.stringify(agentData));
  // console.log(JSON.stringify(agentData));
}

initWebSocket()

// 将方法暴露出去
export {
  sendSocket,
  getSocket,
  createWebSocket,
  closeWebSocket
}
